import express from "express";
import cors from "cors";
import { fileURLToPath } from "url";
import { dirname } from "path";

const __filename = fileURLToPath(import.meta.url);
const __dirname = dirname(__filename);

const app = express();
const PORT = 8000;

// 中间件
app.use(cors());
app.use(express.json());

// AI聊天接口 - 转发到实际的后台
app.post("/chat", async (req, res) => {
    try {
        const { message, type } = req.body;

        if (!message) {
            return res.status(400).json({
                success: false,
                message: "消息内容不能为空",
            });
        }

        console.log(`收到${type === "voice" ? "语音" : "文字"}消息:`, message);

        // 这里可以连接到你的实际AI后台
        // 例如：调用OpenAI API、本地AI模型等
        // 目前返回一个简单的确认消息，表示已收到请求

        const aiResponse = `小维已收到您的${
            type === "voice" ? "语音" : "文字"
        }消息："${message}"。正在处理中...`;

        // 模拟后台处理时间
        setTimeout(() => {
            res.json({
                success: true,
                response: aiResponse,
                message: aiResponse,
                timestamp: new Date().toISOString(),
            });
        }, 300);
    } catch (error) {
        console.error("AI处理错误:", error);
        res.status(500).json({
            success: false,
            message: "服务器内部错误",
        });
    }
});

// 健康检查接口
app.get("/health", (req, res) => {
    res.json({
        status: "ok",
        message: "小维AI服务器运行正常",
        timestamp: new Date().toISOString(),
    });
});

// 启动服务器
app.listen(PORT, () => {
    console.log(`小维AI服务器已启动，监听端口: ${PORT}`);
    console.log(`健康检查: http://localhost:${PORT}/health`);
    console.log(`聊天接口: http://localhost:${PORT}/chat`);
    console.log("注意：当前为转发模式，需要连接到实际的后台AI服务");
});
